Conversation
Add two new GCP Pub/Sub components: - gcp.pubsub.publishMessage: Publish messages to a Pub/Sub topic in JSON or text format. Uses the GCP Pub/Sub REST API. - gcp.pubsub.onTopicMessage: Trigger workflows when messages arrive on a user-specified Pub/Sub topic. Creates a push subscription that delivers messages to the SuperPlane events endpoint. Backend changes: - pkg/integrations/gcp/pubsub/publish_message.go: PublishMessage component - pkg/integrations/gcp/pubsub/on_topic_message.go: OnTopicMessage trigger - pkg/integrations/gcp/pubsub/client.go: Publish and ListTopics API methods - pkg/integrations/gcp/gcp.go: Register components, add /events/pubsub handler - pkg/integrations/gcp/common/common.go: EventsBaseURL in Metadata - Tests for all new code Frontend changes: - web_src/src/pages/workflowv2/mappers/gcp/publish_message.ts - web_src/src/pages/workflowv2/mappers/gcp/on_topic_message.ts - web_src/src/pages/workflowv2/mappers/gcp/index.ts: Register mappers Closes #3095
|
Cursor Agent can help with this pull request. Just |
|
👋 Commands for maintainers:
|
|
/sp start |
|
We hit the limit for ephemeral machine. Stop some running ones. |
|
/sp start |
2 similar comments
|
/sp start |
|
/sp start |
|
✅ Ready. Web: https://pr-3374.ephemeral.superplane.com |
|
/sp stop |
1 similar comment
|
/sp stop |
|
✅ Ephemeral machine has been terminated. |
|
/sp start |
|
✅ Ready. Web: https://pr-3374.ephemeral.superplane.com |
|
/sp stop |
|
✅ Ephemeral machine has been terminated. |
2 participants
feat: expand GCP integration with Pub/Sub publish and subscribe capabilities.
This PR implements issue #3095 by adding two new components to the existing GCP integration:
gcp.pubsub.publishMessage(Action) for publishing messages to a Pub/Sub topic andgcp.pubsub.onTopicMessage(Trigger) for listening to messages on a specified topic.